package com.we.flink.accountuserlabelplatform.table;

import java.sql.Timestamp;

public class TableUser {
    //    public static final String KFKTABLE = "fdm.uni01_user";
    public static final String KFKTABLE = "fdm.uni01_user_risk";
    public static final String QUERYSQL =
            "select user_key as account_user_key, "
                    + "ref_id as user_key,"
                    + "if(update_time is null, TIMESTAMP '1970-01-01 08:00:00.000000', update_time) as update_time "
                    + "from "
                    + KFKTABLE
                    + " where channel_code = 'HAOHUAN'";

    public String account_user_key;
    public String user_key;
    public Timestamp update_time;

    public TableUser() {}

    public TableUser(String account_user_key, String user_key, Timestamp update_time) {
        this.account_user_key = account_user_key;
        this.user_key = user_key;
        this.update_time = update_time;
    }

    public String getUser_key() {
        return user_key;
    }

    public String getAccount_user_key() {
        return account_user_key;
    }

    public Timestamp getUpdate_time() {
        return update_time;
    }
}
